package com.baizhi.routing;

import com.baizhi.util.RabbitMQUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

import java.io.IOException;

public class RabbitRouting {
    public static void main(String[] args) throws IOException {
        //通过连接工厂 得到连接对象
        Connection connection = RabbitMQUtil.getConnection();


        //连接对象得到通道对象
        Channel channel = connection.createChannel();

        //通道对象得到交换机对象 参数1：交换机名称 参数2：交换机leixing
        channel.exchangeDeclare("logs","direct");

        //routingkey
        String key = "";
        //发消息  参数1：往哪个交换机中发消息 参数2：指定routingkey  参数3：消息的额外设置
            //参数4：消息的内容
        channel.basicPublish("logs",key,null,("routing类型的消息"+key).getBytes());

    }
}
